package tools.websocket;

import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;

import java.util.concurrent.BlockingDeque;
import java.util.concurrent.LinkedBlockingDeque;

/**
 * @author lm
 * @date 2022/6/10 14:49
 * @description
 */
@Component
public class CacheVar {
    @Bean(name="socketEndpointQueue")
    public BlockingDeque<SocketEndpoint> traceVehicleQueue(){
        return new LinkedBlockingDeque<>(2000);
    }
}
